<?php
ini_set('date.timezone','Asia/Shanghai');
error_reporting(E_ERROR);

include('./Expand/WxpayAPI_php_v3/lib/WxPay.Exception.php');
include('./Expand/WxpayAPI_php_v3/lib/WxPay.Config.php');
include('./Expand/WxpayAPI_php_v3/lib/WxPay.Data.php');
include('./Expand/WxpayAPI_php_v3/lib/WxPay.Api.php');
include('./Expand/WxpayAPI_php_v3/lib/WxPay.Notify.php');

//初始化日志
//$logHandler= new CLogFileHandler("../logs/".date('Y-m-d').'.log');
//$log = Log::Init($logHandler, 15);

class PayNotifyCallBack extends \WxPayNotify
{
    //查询订单
    public function Queryorder($transaction_id)
    {
        $input = new WxPayOrderQuery();
        $input->SetTransaction_id($transaction_id);
        $result = WxPayApi::orderQuery($input);
        //Log::DEBUG("query:" . json_encode($result));
        if(array_key_exists("return_code", $result)
            && array_key_exists("result_code", $result)
            && $result["return_code"] == "SUCCESS"
            && $result["result_code"] == "SUCCESS")
        {
            return true;
        }
        return false;
    }

    //重写回调处理函数
    public function NotifyProcess($data, &$msg)
    {
        file_put_contents('wxpay.notify', json_encode($data). "\n", FILE_APPEND);

        //Log::DEBUG("call back:" . json_encode($data));
        $notfiyOutput = array();

        if(!array_key_exists("transaction_id", $data)){
            $msg = "输入参数不正确";
            return false;
        }
        //查询订单，判断订单真实性
        if(!$this->Queryorder($data["transaction_id"])){
            $msg = "订单查询失败";
            return false;
        }

        $out_trade_no = $data['out_trade_no'];
        $trade_no = $data['transaction_id'];
        $total_fee = $data['total_fee'];
        $body = $data['attach'];

        $url='http://'.$_SERVER['SERVER_NAME'].$_SERVER["REQUEST_URI"];
        $url = str_replace('wxpay_notify.php', 'index.php', $url);
        $url = $url . "?g=course&m=Course&a=notifyurl_wx&out_trade_no=$out_trade_no&trade_no=$trade_no&total_fee=$total_fee&body=$body";
        file_put_contents('wxpay.notify', $url . "\n", FILE_APPEND);
        file_get_contents($url);

        file_put_contents('wxpay.notify', "OK!!!\n", FILE_APPEND);
        return true;
    }
}

//Log::DEBUG("begin notify");
$notify = new \PayNotifyCallBack();
$notify->Handle(false);

